package com.wudl.core

import org.apache.spark.{SparkConf, SparkContext}

/**
 * 将Rdd 中的每一个元素通过应用的函数， 转化为新的元素，并封装到新RDD 中
 */
object SparkFlatMap {
  def main(args: Array[String]): Unit = {

    val conf = new SparkConf().setMaster("local[*]").setAppName("SparkFlatMap")
    val sc = new SparkContext(conf)

    //  创建一个Rdd

    val rdd = sc.makeRDD(List(List(1, 2), List(3, 4), List(5, 6)))

    rdd.flatMap(list => list).collect().foreach(println)

    sc.stop()


  }

}
